const mysql = require('mysql');
const config = require('../config');//数据库配置模块

//实现数据库连接
function createDB(sql) {
    return new Promise((resolve, reject) => {
        //创建数据连接
       
        const conn = mysql.createConnection({
            host: config.host,       //主机名
            user: config.user,       //数据库用户名
            password: config.pass,   //数据库密码
            database: config.db      //数据库名称
        });
        //建立连接
        conn.connect();
        console.log('数据库连接ok');
        conn.query(sql, (err, result) => {
            if (err) {        //数据库操作失败
                reject(err);
            } else {
               
                console.log('数据库操作ok',result);        //数据库操作成功
                resolve(result);
            }
        });//数据库操作
        conn.end();
    });
}

module.exports = createDB;